package com.sdg.statistics

import org.apache.spark.SparkConf
import org.apache.spark.sql.SparkSession

object GaoTest01 {
  def main(args: Array[String]): Unit = {

    val sparkconf = new SparkConf().setAppName("test").setMaster("local")
    val spark = SparkSession.builder().config(sparkconf).getOrCreate()
    val rdd01 = spark.sparkContext.parallelize(List("A","B","C"))
    val rdd02 = spark.sparkContext.parallelize(List(1,2,3))
    val value = rdd01.cartesian(rdd02)
    value.foreach(println(_))

    spark.stop()
  }

}
